package dao;

import database.ConnexionBD;

public class DAOHistorique {

	// ATTRIBUTS
	private ConnexionBD connexion;
	
	// CONSTRUCTEURS
	public DAOHistorique(ConnexionBD connexion) {
		this.connexion = connexion;
	}
	
	// ACCESSEURS
	public int getNbEcouteByChansonId() {
		
		return 0;
	}
	
	public int getNbEcouteByChansonIdAndUtilisateurId() {
		
		return 0;
	}
	
	public void ajouterEcoute(int idChanson, int idUtilisateur) {
		
		String update_query = "UPDATE historique " +
						"SET nb_ecoute = nb_ecoute + 1, date_derniere_ecoute = CURRENT_TIMESTAMP " + 
						"WHERE id_utilisateur = " + idUtilisateur + " AND id_chanson = " + idChanson;
		
		if (connexion.executeUpdate(update_query) == 0) {
			
			String insert_query = "INSERT INTO historique (id_utilisateur, id_chanson, nb_ecoute) " +
								"VALUES (" + idUtilisateur + ", " + idChanson + ", " + 1 + ")";
			
			connexion.executeUpdate(insert_query);
		}
	}
}
